package top.hkyzf.study.j2se.stream;

import org.junit.Test;
import top.hkyzf.study.j2se.lambda.methodref.Employee;
import top.hkyzf.study.j2se.lambda.methodref.EmployeeData;

import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * Stream的终止操作
 *
 * @author 朱峰
 * @date 2021-8-12 12:08
 */
public class StreamAPITest2 {
    /**
     * 1-查找与匹配
     */
    @Test
    public void test1() {
        List<Employee> employees = EmployeeData.getEmployee();
        // allMatch(Predicate p)——检查是否匹配所有元素。
        //     练习：是否所有的员工的年龄都大于18
        boolean allMatch = employees.stream().allMatch(employee -> employee.getAge() > 18);
        System.out.println(allMatch);

        // anyMatch(Predicate p)——检查是否至少匹配一个元素。
        //     练习：是否存在员工的工资大于10000
        boolean anyMatch = employees.stream().anyMatch(employee -> employee.getSalary() > 10000);
        System.out.println(anyMatch);

        // noneMatch(Predicate p)——检查是否没有匹配的元素。
        //     练习：是否存在员工姓“雷”
        boolean noneMatch = employees.stream().noneMatch(employee -> employee.getName().startsWith("雷"));
        System.out.println(noneMatch);

        // findFirst——返回第一个元素
        Optional<Employee> first = employees.stream().findFirst();
        System.out.println(first);

        // findAny——返回当前流中的任意元素
        Optional<Employee> any = employees.parallelStream().findAny();
        System.out.println(any);
    }

    /**
     * 1-查找与匹配
     */
    @Test
    public void test2() {
        List<Employee> employees = EmployeeData.getEmployee();
        // count——返回流中元素的总个数
        long count = employees.stream().filter(employee -> employee.getSalary() > 5000).count();
        System.out.println(count);

        // max(Comparator c)——返回流中最大值
        //     练习：返回最高的工资:
        Stream<Double> doubleStream = employees.stream().map(emp -> emp.getSalary());
        Optional<Double> max = doubleStream.max(Double::compare);
        System.out.println(max);

        // min(Comparator c)——返回流中最小值
        //     练习：返回最低工资的员工
        // Optional<Employee> min = employees.stream().min((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
        Optional<Employee> min = employees.stream().min(Comparator.comparingDouble(Employee::getSalary));
        System.out.println(min);

        System.out.println("************************");
        // forEach(Consumer c)——内部迭代
        employees.stream().forEach(System.out::println);
        // 使用集合的一个遍历操作
        employees.forEach(System.out::println);
    }

    /**
     * 2-规约
     */
    @Test
    public void test3() {
        // reduce(T identity, BinaryOperator)——可以将流中元素反复结合起来，得到一个值。返回T
        //     练习1：计算1-10的自然数的和
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
        Integer sum = list.stream().reduce(0, Integer::sum);
        System.out.println(sum);

        // reduce(BinaryOperator)——可以将流中元素反复结合起来，得到一个值。返回 Optional<T>
        //     练习2：计算公司所有员工工资的总和
        List<Employee> employees = EmployeeData.getEmployee();
        Stream<Double> doubleStream = employees.stream().map(Employee::getSalary);
        // Optional<Double> reduce = doubleStream.reduce((d1, d2) -> d1 + d2);
        Optional<Double> reduce = doubleStream.reduce(Double::sum);
        System.out.println(reduce);
    }
    /**
     * 3-收集
     */
    @Test
    public void test4 () {
        // collect(Collector c)——将流转换为其他形式。接收一个 Collector 接口的实现，用于给Stream中元素做汇总的方法
        //     练习1：查找工资大于6000的员工，结果返回为一个List或Set
        List<Employee> employees = EmployeeData.getEmployee();
        List<Employee> employeeList = employees.stream().filter(employee -> employee.getSalary() > 6000).collect(Collectors.toList());
        employeeList.forEach(System.out::println);

        System.out.println();
        Set<Employee> employeeSet = employees.stream().filter(employee -> employee.getSalary() > 6000).collect(Collectors.toSet());
        employeeSet.forEach(System.out::println);
    }
}
